
package cn.hz.camel;

import java.io.Serializable;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledExecutorService;

 

public class MzTask  {
 
	
	public void installIns(List<MzClientInput> cls){
		
	   for(MzClientInput cl:cls){
		   MzInRunner irun=new MzInRunner();
		   irun.setClient(cl);
		   MzSource.scheduledThreadPoolIn.execute(irun);
	   }
	}
	
	public void installIn(MzClientInput cl){
		
		  
			   MzInRunner irun=new MzInRunner();
			   irun.setClient(cl);
			   MzSource.scheduledThreadPoolIn.execute(irun);
			   
			   MzResRunner rrun=new MzResRunner();
			   rrun.setClient(cl);
			   MzSource.scheduledThreadPoolRes.execute(rrun);
		   
	}
	
	

	
	public void installOut( MzClientOutput cl){
		
	   
		   MzOutRunner orun=new MzOutRunner();
		   orun.setClient(cl);
		   MzSource.scheduledThreadPoolOut.execute(orun);
	   
	}
	
}
